// Copyright 2023 Harness, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package importer

import (
	"context"
	"fmt"

	repoevents "github.com/harness/gitness/app/events/repo"
	"github.com/harness/gitness/app/services/keywordsearch"
	"github.com/harness/gitness/app/services/publicaccess"
	"github.com/harness/gitness/app/services/refcache"
	"github.com/harness/gitness/app/services/settings"
	"github.com/harness/gitness/app/sse"
	"github.com/harness/gitness/app/store"
	"github.com/harness/gitness/app/url"
	"github.com/harness/gitness/audit"
	"github.com/harness/gitness/encrypt"
	"github.com/harness/gitness/git"
	"github.com/harness/gitness/job"
	"github.com/harness/gitness/store/database/dbtx"
	"github.com/harness/gitness/types"

	"github.com/google/wire"
)

var WireSet = wire.NewSet(
	ProvideImporter,
	ProvideJobRepositoryImport,
	ProvideJobRepositoryLink,
	ProvideJobReferenceSync,
)

func ProvideConnectorService() ConnectorService {
	return connectorServiceNoop{}
}

func ProvideImporter(
	config *types.Config,
	urlProvider url.Provider,
	git git.Interface,
	tx dbtx.Transactor,
	repoStore store.RepoStore,
	pipelineStore store.PipelineStore,
	triggerStore store.TriggerStore,
	repoFinder refcache.RepoFinder,
	sseStreamer sse.Streamer,
	indexer keywordsearch.Indexer,
	publicAccess publicaccess.Service,
	eventReporter *repoevents.Reporter,
	auditService audit.Service,
	settings *settings.Service,
) *Importer {
	return NewImporter(
		config.Git.DefaultBranch,
		urlProvider,
		git,
		tx,
		repoStore,
		pipelineStore,
		triggerStore,
		repoFinder,
		sseStreamer,
		indexer,
		publicAccess,
		eventReporter,
		auditService,
		settings,
	)
}

func ProvideJobRepositoryImport(
	encrypter encrypt.Encrypter,
	scheduler *job.Scheduler,
	executor *job.Executor,
	importer *Importer,
) (*JobRepository, error) {
	j := &JobRepository{
		encrypter: encrypter,
		scheduler: scheduler,
		importer:  importer,
	}

	if err := executor.Register(jobTypeRepositoryImport, j); err != nil {
		return nil, err
	}

	return j, nil
}

func ProvideJobRepositoryLink(
	ctx context.Context,
	config *types.Config,
	encrypter encrypt.Encrypter,
	scheduler *job.Scheduler,
	executor *job.Executor,
	importer *Importer,
	urlProvider url.Provider,
	git git.Interface,
	repoFinder refcache.RepoFinder,
	linkedRepoStore store.LinkedRepoStore,
	indexer keywordsearch.Indexer,
	connectorService ConnectorService,
) (*JobRepositoryLink, error) {
	j := &JobRepositoryLink{
		encrypter: encrypter,
		scheduler: scheduler,
		importer:  importer,
	}

	if err := executor.Register(jobTypeRepositoryLink, j); err != nil {
		return nil, err
	}

	if err := CreateAndRegisterJobSyncLinkedRepositories(
		ctx,
		scheduler,
		executor,
		config.Git.DefaultBranch,
		urlProvider,
		git,
		repoFinder,
		linkedRepoStore,
		indexer,
		connectorService,
	); err != nil {
		return nil, fmt.Errorf("unable to register job sync linked repositories: %w", err)
	}

	return j, nil
}

func ProvideJobReferenceSync(
	config *types.Config,
	urlProvider url.Provider,
	git git.Interface,
	repoStore store.RepoStore,
	repoFinder refcache.RepoFinder,
	scheduler *job.Scheduler,
	executor *job.Executor,
	indexer keywordsearch.Indexer,
	eventReporter *repoevents.Reporter,
) (*JobReferenceSync, error) {
	importer := &JobReferenceSync{
		defaultBranch: config.Git.DefaultBranch,
		urlProvider:   urlProvider,
		git:           git,
		repoStore:     repoStore,
		repoFinder:    repoFinder,
		scheduler:     scheduler,
		indexer:       indexer,
		eventReporter: eventReporter,
	}

	err := executor.Register(refSyncJobType, importer)
	if err != nil {
		return nil, err
	}

	return importer, nil
}
